package org.hyf.inspur.LessonDesin.clear.wordcount;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

import java.io.IOException;

public class WordCountReducer extends Reducer<Text,IntWritable,IntWritable,Text>{

	@Override
	protected void reduce(Text key, Iterable<IntWritable> values,
			Context context)
			throws IOException, InterruptedException {
		int sum = 0;
		for (IntWritable tmp : values) {
			int tmpNum = tmp.get();
			sum++;
		}
		context.write(new IntWritable(sum),key);
	}
}
